2c16d4de73836decbf50acf749588f6c50fb1736,aggregate-snapshot/aggregate-snapshot-service/src/test/java/uk/gov/justice/services/core/aggregate/SnapshotAwareAggregateServiceIT.java,SnapshotAwareAggregateServiceIT,createEventStreamAndApply,#number#String#T#,420
Before Change
private <T extends Aggregate> Stream<JsonEnvelope> createEventStreamAndApply(long count, String eventName, T aggregate) {
List<Object> envelopes = new LinkedList<>();
for (int i = 1; i <= count; i++) {
JsonEnvelope envelope = envelope().with(metadataWithRandomUUID(eventName).withStreamId(STREAM_ID)).withPayloadOf("value", "name").build();
aggregate.apply(new EventA(String.valueOf(i)));
envelopes.add(envelope);
}
After Change
JsonEnvelope envelope =
envelope()
.with(metadataWithRandomUUID(eventName)
.createdAt(clock.now())
.withStreamId(STREAM_ID))
.withPayloadOf("value", "name")
.build();